/**
 * Created by Administrator on 2017/4/22.
 */
//1.首先引用数据库连接文件
var mongo = require('./db');

function User(user) {
    this.name = user.name;
    this.password = user.password;
    this.email = user.email;
    this.message = user.message;
}
module.exports = User;
//保存用户注册信息
User.prototype.save = function (callback) {
    var user = {
        name:this.name,
        password:this.password,
        email:this.email,
        message:this.message
    }
    //打开数据库
    mongo.open(function (err, db) {
        if(err){
            return callback(err);
        }
        //读取users集合
        db.collection('users',function (err, collection) {
            if(err){
                mongo.close();
                return callback(err);
            }
            //将用户数据插入集合users中
            collection.insert(user,{safe:true},function (err, user) {
                mongo.close();
                if(err){
                    return callback(err);
                }
                //成功返回用户名user[0]
                callback(null,user[0]);
            })
        })
    })
}
//读取用户信息
User.get = function (name, callback) {
    mongo.open(function (err, db) {
        if(err){
            return callback(err);
        }
        db.collection('users',function (err, collection) {
            if(err){
                mongo.close();
                return callback(err);
            }
            //查询用户名的文档
            collection.findOne({name:name},function (err, user) {
                mongo.close();
                if(err){
                    return callback(err);
                }
                //成功就返回用户信息
                // console.log(user);
                return callback(null,user);
            })
        })
    })
}